package com.lk.recvice.server.keepalive;

import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

import com.lk.base.config.PropConf;
import com.lk.base.utils.DateUtil;

import io.netty.util.HashedWheelTimer;
import io.netty.util.Timeout;
import io.netty.util.Timer;
import io.netty.util.TimerTask;


@Component(value = "MyMqttClient")
@Order(2)
public class MyMqttClient  implements ApplicationRunner{

    public static MqttClient mqttClient = null;
    private static MemoryPersistence memoryPersistence = null;
    private static MqttConnectOptions mqttConnectOptions = null;
    private static String ClientName = "";				//待填	将在服务端出现的名字
//    private static String IP = PropConf.getValueByKey("keepalive.ip");
//    private static String PORT = PropConf.getValueByKey("keepalive.port");		
    public static String IP = "192.168.31.29";
    public static String PORT = "502";		
    private static String USERNAME = PropConf.getValueByKey("username");
    private static String PASSWORD = PropConf.getValueByKey("password");
    
    public static void main(String[] args) {
    }


    @Override
	public void run(ApplicationArguments args) throws Exception {
    	
	}

}